var MongoClient = require('mongodb').MongoClient
var url = "mongodb://127.0.0.1:27017"

MongoClient.connect(url, {useNewUrlParser: true, useUnifiedTopology: true}, function(err, db){
  if(err) throw err
  var dbo = db.db("laochen")
  dbo.collection('orders').aggregate([
    {
      $lookup: {
        from: 'products',         // 右集合
        localField: 'product_id', // 左集合join字段
        foreignField: '_id',      // 右集合join字段
        as: 'orderdetails'        // 新生成字段（类型array）
      }
    }
  ]).toArray(function(err, res) {
    if(err) throw err;
    console.log(JSON.stringify(res))
    db.close()
  })
})